package com.xzcedu.upload;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

/**
 * @author 徐州城
 * @version 1.0
 * 文件上传的客户端
 * 1. 编写一个服务端，和一个客户端
 * 2. 服务器再8888端口监听
 * 3. 客户端连接到服务端，发送 一张图片 e:\\qie.png
 * 4. 服务端接收到 客户端发送的图片，保存到 src下，发送 "收到图片" 再退出
 * 5. 客户端收到服务端发送的 "收到图片"，再退出
 * 6. 该程序要求使用 StreamUtils.java
 * 说明：使用BufferedInputStream 和 BufferedOutputStream 字节流
 */
public class TCPFileUploadClient {
    public static void main(String[] args) throws Exception {

        //客户端连接服务端，得到Socket对象
        Socket socket = new Socket(InetAddress.getLocalHost(), 8888);
        //创建读取磁盘文件的输入流
        String filePath = "e:\\qie.jpg";
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream(filePath));//处理流

        //bytes 就是filePath对应的字节数组
        byte[] bytes = StreamUtils.streamToByteArray(bis);

        //通过socket 获取到输出流，将bytes数据发送给服务端
        OutputStream outputStream = socket.getOutputStream();
        BufferedOutputStream bos = new BufferedOutputStream(outputStream);
        bos.write(bytes);//将文件对应的字节数组的内容，写入到数据通道
        socket.shutdownOutput();//设置写入数据的结束标记

        //接收 服务端的信息
        InputStream inputStream = socket.getInputStream();
        byte[] buf = new byte[1024];
        int readLen;
        while ((readLen = inputStream.read(buf)) != -1) {
            System.out.println(new String(buf, 0, readLen));
        }

        //关闭相关的流
        bos.close();
        bis.close();
        inputStream.close();
        socket.close();
    }
}
